jvn.JvnServerImpl Class Reference

Inheritance diagram for jvn.JvnServerImpl:

[legend]

Collaboration diagram for jvn.JvnServerImpl:

[legend]

List of all members.

Public Member Functions
void	jvnTerminate () throws jvn.JvnException
JvnObject	jvnCreateObject (Serializable o) throws jvn.JvnException
void	jvnRegisterObject (String jon, JvnObject jo) throws jvn.JvnException
JvnObject	jvnLookupObject (String jon, Class<?extends JvnObject > type) throws jvn.JvnException
Serializable	jvnLockRead (int joi) throws JvnException
Serializable	jvnLockWrite (int joi) throws JvnException
void	jvnInvalidateReader (int joi) throws java.rmi.RemoteException,jvn.JvnException
Serializable	jvnInvalidateWriter (int joi) throws java.rmi.RemoteException,jvn.JvnException
Serializable	jvnInvalidateWriterForReader (int joi) throws java.rmi.RemoteException,jvn.JvnException
Static Public Member Functions
static JvnServerImpl	jvnGetServer ()
Private Member Functions
	JvnServerImpl () throws Exception
Private Attributes
HashMap< Integer, JvnObject >	jvnObjectIds = null
JvnRemoteCoord	jvnCoordinator = null
Static Private Attributes
static final long	serialVersionUID = -1834717182805714127L
static JvnServerImpl	js = null

---

Detailed Description

This class implements the Javanaise Server.

Definition at line 22 of file JvnServerImpl.java.

---

Constructor & Destructor Documentation

jvn.JvnServerImpl.JvnServerImpl

(

)

throws Exception [private]

Default constructor

Definition at line 46 of file JvnServerImpl.java.

References jvn.JvnServerImpl.jvnCoordinator, and jvn.JvnServerImpl.jvnObjectIds.

Referenced by jvn.JvnServerImpl.jvnGetServer().

                                                 {
                jvnObjectIds = new HashMap<Integer,JvnObject>();
                try {
                        jvnCoordinator = (JvnRemoteCoord)Naming.lookup("AT_LD_jvnCoordinator");
                } catch(NotBoundException e) {
                        System.out.println("Coordinator not found!");
                        jvnCoordinator = null;
                }
        }

Here is the caller graph for this function:

---

Member Function Documentation

static JvnServerImpl jvn.JvnServerImpl.jvnGetServer

(

)

[static]

Static method allowing an application to get a reference to the instance of the Javanaise Server (managed as a singleton, remember)

Returns:

A valid JvnServerImpl reference if server can be created AND coordinator can be located, null otherwise.

Definition at line 63 of file JvnServerImpl.java.

References jvn.JvnServerImpl.js, and jvn.JvnServerImpl.JvnServerImpl().

                                                   {
                if (js == null) {
                        try {
                                js = new JvnServerImpl();
                        } catch (Exception e) {
                                System.out.println("Error creating the Javanaise Server!\n"+e);
                                return null;
                        }
                }
                return js;
        }

Here is the call graph for this function:

void jvn.JvnServerImpl.jvnTerminate

(

)

throws jvn.JvnException

Terminates the Javanaise Server.

Implements jvn.JvnLocalServer.

Definition at line 78 of file JvnServerImpl.java.

References jvn.JvnServerImpl.jvnCoordinator, and jvn.JvnRemoteCoord.jvnServerTerminated().

                                                           {
                JvnRemoteCoord coord = null;
                synchronized(this) {
                        if(jvnCoordinator!=null) {
                                coord = jvnCoordinator;
                                jvnCoordinator = null;
                        }
                }

                System.out.println("Terminating the Javanaise Server");

                try {
                        if (coord != null) {
                                coord.jvnServerTerminated(this);
                        }
                } catch (RemoteException e) {}
        }

Here is the call graph for this function:

JvnObject jvn.JvnServerImpl.jvnCreateObject

(

Serializable

o

)

throws jvn.JvnException

Creates a Javanaise Object. Note that once created, the object is not registered to any Javanaise Service, it doesn't even have a valid Javanaise Object ID.

See also:

JvnServerImpl#jvnRegisterObject(String, JvnObject)

Parameters:

o

: Initial content (state) of the Javanaise Object.

Returns:

A dummy Javanaise Object with the given content.

Implements jvn.JvnLocalServer.

Definition at line 107 of file JvnServerImpl.java.

Referenced by irc.Irc.main(), and counter.Counter.main().

                                {
                return new JvnObjectImpl(o);
        }

Here is the caller graph for this function:

void jvn.JvnServerImpl.jvnRegisterObject	(	String	jon,
		JvnObject	jo
	)			throws jvn.JvnException

Gets a Javanaise Object ID for the object and registers it with the Javanaise Coordinator. Once this method succeeds, the object is accessible from all clients member of that Javanaise Service. The current server will hold a cached version of that object.

Parameters:

	jon	: the JVN object name
	jo	: the JVN object

Implements jvn.JvnLocalServer.

Definition at line 121 of file JvnServerImpl.java.

References jvn.JvnServerImpl.jvnCoordinator, jvn.JvnRemoteCoord.jvnGetObjectId(), jvn.JvnServerImpl.jvnObjectIds, and jvn.JvnRemoteCoord.jvnRegisterObject().

Referenced by irc.IrcJvn2.main(), irc.Irc.main(), counter.CounterJvn2.main(), and counter.Counter.main().

                                                                                        {
                if(jvnCoordinator == null) {
                        throw new JvnException("Coordinator is not present!");
                } else if(jo == null || jon == null) {
                        throw new JvnException("The given name or JvnObject is not valid!");
                } else {
                        try {
                                int id = jvnCoordinator.jvnGetObjectId();
                                jo.jvnSetObjectId(id);
                                jvnCoordinator.jvnRegisterObject(jon,jo,this);

                                // Only put in cache after successful registration
                                jvnObjectIds.put(id,jo);
                        } catch (RemoteException e) {
                                throw new JvnException("Network error while registering object!\n" + e);
                        }
                }
        }

Here is the call graph for this function:

Here is the caller graph for this function:

JvnObject jvn.JvnServerImpl.jvnLookupObject	(	String	jon,
		Class<?extends JvnObject >	type
	)			throws jvn.JvnException

Gets a reference to a Javanaise Object based on its symbolic name.

Parameters:

	jon	: the JVN object name
	type	: the class type of the desired object

Returns:

A reference to the JVN object. Before using that reference, make sure you've done a read lock or a write lock on it.

Implements jvn.JvnLocalServer.

Definition at line 149 of file JvnServerImpl.java.

References jvn.JvnServerImpl.jvnCoordinator, jvn.JvnObject.jvnGetObjectId(), jvn.JvnRemoteCoord.jvnLookupObject(), and jvn.JvnServerImpl.jvnObjectIds.

Referenced by irc.IrcJvn2.main(), irc.Irc.main(), counter.CounterJvn2.main(), and counter.Counter.main().

                                                                                                              {
                /*if(jvnCoordinator == null) {
                        throw new JvnException("Coordinator is not present!");
                }*/
                if (jon == null) {
                        throw new JvnException("The given name is not valid!");
                }
                if (type == null) {
                        throw new JvnException("The given class type is not valid!");
                }
                else {
                        try {
                                //System.out.println(type.getName());
                                JvnObject temp = jvnCoordinator.jvnLookupObject(jon, type, this);
                                //System.out.println(temp);
                                if (temp != null) {
                                        // A Javanaise object with name <jon> exists.
                                        
                                        // String-comparison-based type checking !
                                        if (temp.toString().startsWith(type.getName())) {
//                                      if (temp.getClass().getName().startsWith(type.getName())) {
                                                try {
                                                        // Try typecast...
                                                        // This is supposed to handle JvnObject vs. JvnObjectImpl,
                                                        // which string-comparison-based type checking cannot do
                                                        // cleanly.
                                                        temp.getClass().asSubclass(type);
                                                        // The Javanaise object with name <jon> has the same type as the
                                                        // given type, so we assume that it is the same object.
                                                        jvnObjectIds.put(temp.jvnGetObjectId(), temp);
                                                        ((JvnObjectImpl)temp).__containedObjectLockState = JvnObjectState.STATE_NOLOCK;
                                                }
                                                catch (ClassCastException e) {
                                                        System.err.println(type.getName());
                                                        System.err.println(temp.toString());
                                                        throw new JvnException("Object with same name, but different type, previously registered (2)!");
                                                }
                                                
                                        }
                                        else {
                                                // Rare case: there is already a Javanaise object with name <jon>,
                                                // but the type of that object is different from the given type...
                                                // Trying to use the previously registered object may trigger all
                                                // kinds of exceptions: ClassCastException, NoSuchMethodException, etc.
                                                // We'd better signaling there's a problem.
                                                System.err.println(type.getName());
                                                System.err.println(temp.toString());
                                                throw new JvnException("Object with same name, but different type, previously registered (1)!");
                                        }
                                }
                                
                                //try {
                                        //c = (type.class)o;
                                        //type.class temp = (JvnObject)o;
                                        //if (o instanceof c)
                                        //Class.forName(className)
                                        if(temp!=null) {
                                        }
                                        return temp;
                                //}
                        } catch(RemoteException e) {
                                throw new JvnException("Network error!\n"+e);
                        } catch(ClassCastException e) {
                                throw new JvnException("Unexpected class type!");
                        }
                }
        }

Here is the call graph for this function:

Here is the caller graph for this function:

Serializable jvn.JvnServerImpl.jvnLockRead

(

int

joi

)

throws JvnException

Get a read lock on a JVN object.

Before trying to get any lock, you must get a reference to the object using the JvnServerImpl#jvnLookupObject(String) method.

Parameters:

joi

: the JVN object identification

Returns:

The current JVN object state

Implements jvn.JvnLocalServer.

Definition at line 227 of file JvnServerImpl.java.

References jvn.JvnServerImpl.jvnCoordinator, jvn.JvnRemoteCoord.jvnLockRead(), and jvn.JvnServerImpl.jvnObjectIds.

                                                                     {
                if(jvnCoordinator == null) {
                        throw new JvnException("Coordinator is not present!");
                } else if( jvnObjectIds.containsKey(joi) ) {
                        try {
                                return jvnCoordinator.jvnLockRead(joi,this);
                        } catch (RemoteException e) {
                                throw new JvnException("Network error while locking object for reading!\n" + e);
                        }
                } else {
                        throw new JvnException("Unknown object ID! Plase call jvnLookupObject before calling this method!");
                }
        }

Here is the call graph for this function:

Serializable jvn.JvnServerImpl.jvnLockWrite

(

int

joi

)

throws JvnException

Get a write lock on a JVN object.

Before trying to get any lock, you must get a reference to the object using the JvnServerImpl#jvnLookupObject(String) method.

Parameters:

joi

: the JVN object identification

Returns:

The current JVN object state

Implements jvn.JvnLocalServer.

Definition at line 250 of file JvnServerImpl.java.

References jvn.JvnServerImpl.jvnCoordinator, jvn.JvnRemoteCoord.jvnLockWrite(), and jvn.JvnServerImpl.jvnObjectIds.

                                                                      {
                if(jvnCoordinator == null) {
                        throw new JvnException("Coordinator is not present!");
                } else if( jvnObjectIds.containsKey(joi) ) {
                        try {
                                return jvnCoordinator.jvnLockWrite(joi,this);
                        } catch (RemoteException e) {
                                throw new JvnException("Network error while locking object for reading!\n" + e);
                        }
                } else {
                        throw new JvnException("Unknown object ID! Plase call jvnLookupObject before calling this method!");
                }
        }

Here is the call graph for this function:

void jvn.JvnServerImpl.jvnInvalidateReader

(

int

joi

)

throws java.rmi.RemoteException,jvn.JvnException

Invalidates the read lock held by a Javanaise Object. This method is normally called by the Javanaise Coordinator.

Parameters:

joi

: the JVN object id

See also:

JvnObjectImpl.jvnInvalidateReader()

Implements jvn.JvnRemoteServer.

Definition at line 273 of file JvnServerImpl.java.

References jvn.JvnObject.jvnInvalidateReader(), and jvn.JvnServerImpl.jvnObjectIds.

                                                                                                  {
                JvnObject jo = jvnObjectIds.get(joi);

                if( jo==null ) {
                        throw new JvnException("Object id not found while invalidating reader!");
                } else {
                        jo.jvnInvalidateReader();
                }
        }

Here is the call graph for this function:

Serializable jvn.JvnServerImpl.jvnInvalidateWriter

(

int

joi

)

throws java.rmi.RemoteException,jvn.JvnException

Invalidates the write lock held by a Javanaise Object. This method is normally called by the Javanaise Coordinator.

Parameters:

joi

: the JVN object id

See also:

JvnObjectImpl.jvnInvalidateWriter()

Implements jvn.JvnRemoteServer.

Definition at line 291 of file JvnServerImpl.java.

References jvn.JvnObject.jvnInvalidateWriter(), and jvn.JvnServerImpl.jvnObjectIds.

                                                                                                          {
                JvnObject jo = jvnObjectIds.get(joi);

                if( jo==null ) {
                        throw new JvnException("Object id not found while invalidating reader!");
                } else {
                        return jo.jvnInvalidateWriter();
                }
        }

Here is the call graph for this function:

Serializable jvn.JvnServerImpl.jvnInvalidateWriterForReader

(

int

joi

)

throws java.rmi.RemoteException,jvn.JvnException

Invalidates the write lock held by a Javanaise Object and replaces it with a read lock. This method is normally called by the Javanaise Coordinator.

Parameters:

joi

: the JVN object id

See also:

JvnObjectImpl.jvnInvalidateWriterForReader()

Implements jvn.JvnRemoteServer.

Definition at line 310 of file JvnServerImpl.java.

References jvn.JvnObject.jvnInvalidateWriterForReader(), and jvn.JvnServerImpl.jvnObjectIds.

                                                                                                                   {
                JvnObject jo = jvnObjectIds.get(joi);

                if( jo==null ) {
                        throw new JvnException("Object id not found while invalidating reader!");
                } else {
                        return jo.jvnInvalidateWriterForReader();
                }
        }

Here is the call graph for this function:

---

Member Data Documentation

final long jvn.JvnServerImpl.serialVersionUID = -1834717182805714127L [static, private]

Automatically generated serial version ID

Definition at line 26 of file JvnServerImpl.java.

JvnServerImpl jvn.JvnServerImpl.js = null [static, private]

A Javanaise Server is managed as a singleton

Definition at line 31 of file JvnServerImpl.java.

Referenced by jvn.JvnServerImpl.jvnGetServer().

HashMap<Integer,JvnObject> jvn.JvnServerImpl.jvnObjectIds = null [private]

Maps Object IDs to Javanaise Objects.

Definition at line 36 of file JvnServerImpl.java.

Referenced by jvn.JvnServerImpl.jvnInvalidateReader(), jvn.JvnServerImpl.jvnInvalidateWriter(), jvn.JvnServerImpl.jvnInvalidateWriterForReader(), jvn.JvnServerImpl.jvnLockRead(), jvn.JvnServerImpl.jvnLockWrite(), jvn.JvnServerImpl.jvnLookupObject(), jvn.JvnServerImpl.jvnRegisterObject(), and jvn.JvnServerImpl.JvnServerImpl().

JvnRemoteCoord jvn.JvnServerImpl.jvnCoordinator = null [private]

The Javanaise Coordinator.

Definition at line 41 of file JvnServerImpl.java.

Referenced by jvn.JvnServerImpl.jvnLockRead(), jvn.JvnServerImpl.jvnLockWrite(), jvn.JvnServerImpl.jvnLookupObject(), jvn.JvnServerImpl.jvnRegisterObject(), jvn.JvnServerImpl.JvnServerImpl(), and jvn.JvnServerImpl.jvnTerminate().

---

The documentation for this class was generated from the following file:

• JvnServerImpl.java

---